package com.insight.common.mq.subscribe.entity;

import lombok.AllArgsConstructor;
import lombok.Getter;
import lombok.Setter;
import com.insight.common.mq.stream.Streams;
import org.springframework.data.redis.connection.stream.MapRecord;
import org.springframework.data.redis.stream.StreamListener;

/**
 * @author JinPengDong
 * @date 2023/12/19
 */
@Getter
@Setter
@AllArgsConstructor
public class SubscribeMessage {
    private StreamListener<String, MapRecord<String, String, String>> listener;

    private Streams streams;
}
